package com.example.iot.queue;

/**
 * @author ChenXiangpeng
 */
public interface QueueProducer<T> {

    void init();

    String getDefaultTopic();

    void send(TopicPartitionInfo tpi, T msg, QueueCallback callback);

    void stop();
}
